// 云函数入口文件
const cloud = require("wx-server-sdk");

cloud.init({
  env: cloud.DYNAMIC_CURRENT_ENV,
});

const db = cloud.database();
const _ = db.command;

// 云函数入口函数
exports.main = async (event, context) => {
  const {
    category, // 分类：hot-热销，new-新品，special-特价
    page = 1, // 页码
    pageSize = 10, // 每页数量
    merchantId, // 商家ID，可选
  } = event;

  try {
    // 构建查询条件
    const query = {
      status: 1, // 状态：1-上架，0-下架
    };

    // 添加分类条件
    if (category) {
      query.category = category;
    }

    // 添加商家条件
    if (merchantId) {
      query.merchantId = merchantId;
    }

    // 查询总数
    const countResult = await db.collection("dishes").where(query).count();
    const total = countResult.total;

    // 查询列表
    const listResult = await db
      .collection("dishes")
      .where(query)
      .skip((page - 1) * pageSize)
      .limit(pageSize)
      .orderBy("createTime", "desc")
      .get();

    return {
      code: 0,
      msg: "获取成功",
      data: {
        list: listResult.data,
        total,
        page,
        pageSize,
      },
    };
  } catch (err) {
    console.error(err);
    return {
      code: -1,
      msg: "获取失败",
      error: err,
    };
  }
};
